package cc.shacocloud.redis.study.queue.message;

import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.Setter;

import java.util.List;

@Setter
@Getter
@NoArgsConstructor
public class MessageConsumerMo {

    /**
     * 队列名称
     */
    private String queueName;

    /**
     * 消息
     */
    private List<MessageMo> messages;


    @Setter
    @Getter
    @NoArgsConstructor
    public static class MessageMo {

        /**
         * 消息id
         */
        private String messageId;

        /**
         * 消息
         */
        private byte[] message;

    }


}
